//package mn.idax.exchange.otc.atmosphere;
//
//import org.atmosphere.cpr.AtmosphereConfig;
//import org.atmosphere.cpr.Broadcaster;
//import org.atmosphere.plugin.redis.RedisBroadcaster;
//import org.atmosphere.plugin.redis.RedisUtil;
//import org.atmosphere.util.AbstractBroadcasterProxy;
//
//import java.net.URI;
//
///**
// * @Auther: dison
// * @Date: 2018/10/16 16:38
// * @Description:
// */
//public class AtmosphereRedisBrodcaster extends AbstractBroadcasterProxy {
//
//    private RedisUtil redisUtil;
//
//    public Broadcaster initialize(String id, AtmosphereConfig config) {
//        return this.initialize(id, URI.create("http://127.0.0.1:6379"), config);
//    }
//
//    public Broadcaster initialize(String id, URI uri, AtmosphereConfig config) {
//        uri = URI.create("http://127.0.0.1:6379");
//        super.initialize(id, uri, config);
//        this.redisUtil = new RedisUtil(uri, config, new RedisUtil.Callback() {
//            public String getID() {
//                return AtmosphereRedisBrodcaster.this.getID();
//            }
//
//            public void broadcastReceivedMessage(String message) {
//                AtmosphereRedisBrodcaster.this.broadcastReceivedMessage(message);
//            }
//        });
//        this.setUp();
//        return this;
//    }
//
//    public String getAuth() {
//        return this.redisUtil.getAuth();
//    }
//
//    public void setAuth(String auth) {
//        this.redisUtil.setAuth(auth);
//    }
//
//    public synchronized void setUp() {
//        this.redisUtil.configure();
//    }
//
//    public synchronized void setID(String id) {
//        super.setID(id);
//        this.setUp();
//        this.reconfigure();
//    }
//
//    public void destroy() {
//        super.destroy();
//        this.redisUtil.destroy();
//    }
//
//    @Override
//    public void incomingBroadcast() {
//        this.redisUtil.incomingBroadcast();
//    }
//
//    @Override
//    public void outgoingBroadcast(Object message) {
//        this.redisUtil.outgoingBroadcast(message);
//    }
//}
